package com.ruoyi.framework.config.webSocket;

//import com.ruoyi.project.mapper.ProjcetMessageMapper;

/**
 * @author Siona
 * @date 2020/4/9 10:12
 **/
//@Component  // 被Spring容器管理
//@Order(1)   // 如果多个自定义ApplicationRunner，用来表明执行顺序
//public class PushAlarm implements ApplicationRunner {   // 服务启动后自动加载该类
public class PushAlarm  {   // 服务启动后自动加载该类

//    @Autowired
//    ProjcetMessageMapper messageMapper;
//
//    @Override
//    public void run(ApplicationArguments args) throws Exception {
//        System.out.println("------------->" + "项目启动，now =" + new Date());
//        this.myTimer();
//    }
//
//    public void myTimer() {
//
//        String userId = null; // userId 为空时，会推送给连接此 WebSocket 的所有人
//
//        Runnable runnable1 = new Runnable() {
//            @Override
//            public void run() {
//                while (true) {
//                    String message = "测试一下"; // 第三方接口返回数据
//                    try {
//                        WebSocketServer.sendInfo(message, userId); // 推送
//                        Thread.sleep(5000);
//                    } catch (Exception e) {
//                        e.printStackTrace();
//                    }
//
//                }
//            }
//        };
//
//        Runnable runnable2 = new Runnable() {
//            @Override
//            public void run() {
//                while (true) {
//                    String message = "测试一下1"; // 第三方接口返回数据
//                    try {
//                        WebSocketServer.sendInfo(message, userId); // 推送
//                        Thread.sleep(5000);
//                    } catch (Exception e) {
//                        e.printStackTrace();
//                    }
//                }
//            }
//        };
//
//        Thread thread1 = new Thread(runnable1);
//        Thread thread2 = new Thread(runnable2);
//
//        thread1.start();
//        thread2.start();
//
//    }

}
